//package com.ocom.aiot.utils;
//
//
//import org.springframework.amqp.core.Message;
//import org.springframework.amqp.core.MessageBuilder;
//import org.springframework.amqp.core.MessageProperties;
//import org.springframework.amqp.rabbit.connection.CorrelationData;
//import org.springframework.amqp.rabbit.core.RabbitTemplate;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component;
//
//
//@Component
//public class RabbitGoodsStockUitl implements RabbitTemplate.ConfirmCallback{
//
//	@Autowired
//	private RabbitTemplate rabbitTemplate;
//
//	/**
//	 *
//	 * @param orderId
//	 * @param priority	优先级
//	 */
//	public void send(String orderId,Integer priority) {
//		// 封装消息
//		Message message = MessageBuilder.withBody(orderId.getBytes()).setContentType(MessageProperties.CONTENT_TYPE_JSON)
//				.setPriority(priority).setContentEncoding("utf-8").setMessageId(orderId).build();
//
//
//		// 构建回调返回的数据
//		CorrelationData correlationData = new CorrelationData(orderId);
//		// 发送消息
//		rabbitTemplate.setMandatory(true);
//		rabbitTemplate.setConfirmCallback(this);
//		rabbitTemplate.convertAndSend("order_goods_stock_exchange", "routingKeys", message, correlationData);
//		System.out.println("消息发送完成了 。。。。。。。。。");
//		System.out.println("消息发送完成了 。。。。。。。。。");
//		System.out.println("消息发送完成了 。。。。。。。。。");
//	}
//
//	@Override
//	public void confirm(CorrelationData correlationData, boolean ack, String cause) {
//		String orderId = correlationData.getId(); //id 都是相同的哦  全局ID
//		System.out.println("消息id:" + correlationData.getId());
//		if (ack) { //消息发送成功
//			System.out.println("消息发送 确认成功");
//		} else {
//			//重试机制
//			send(orderId,1);
//			System.out.println("消息发送 确认失败:" + cause);
//		}
//	}
//
//}
